#include "../../common/rabbitmq.hpp"


DEFINE_string(user, "root", "rabbitmq用户名称");
DEFINE_string(pwd, "299274142", "rabbitmq用户密码");
DEFINE_string(host, "127.0.0.1:5672", "主机地址 host:port");

DEFINE_bool(run_mode, false, "程序的运行模式, fasle-调试; true-发布;");
DEFINE_string(log_file, "", "发布模式下, 用于指定日志的输出文件");
DEFINE_int32(log_level, 0, "发布模式下, 用于指定日志输出等级");  //trace default 0

int main(int argc, char *argv[])
{
    google::ParseCommandLineFlags(&argc, &argv, true);
    init_logger(FLAGS_run_mode, FLAGS_log_file, FLAGS_log_level);

    MQClient client(FLAGS_user, FLAGS_pwd, FLAGS_host);

    client.declareComponents("test-exchange", "test-queue");
    for(int i = 0; i < 10; i ++)
    {
        std::string msg = "hello - " + std::to_string(i);
        bool ret = client.publish("test-exchange", msg);
        if(!ret)
        {
            std::cout << "publish false" << std::endl;
        }
    }
    std::this_thread::sleep_for(std::chrono::seconds(3));
    return 0;
}